package com.yugao.fintech.draper.message.queue.support;

import com.yugao.fintech.draper.message.queue.message.AbstractBroadcastMessage;
import com.yugao.fintech.draper.message.queue.message.AbstractGroupMessage;

public interface MessageQueueOperations {

	/**
	 * 发送分组消息，此消息对于同一个消费者组仅会被消费一次
	 */
	<T extends AbstractGroupMessage> void send(T message);

	/**
	 * 发送广播消息，此消息对于所有订阅的消费者都会收到
	 */
	<T extends AbstractBroadcastMessage> void send(T message);

}
